import reactor.core.publisher.Flux;

/**
 * @author xuguan
 * @since 2025/11/11
 */
public class ReactorLearn {

	public static void createFlux() {
		Flux.create(fluxSink -> {
			for (int i = 0; i < 10; i++) {
				fluxSink.next(i);
			}

		}).subscribe(System.out::println);
	}

	public static void main(String[] args) {
		// createFlux();
		System.out.println("def calculate_fibonacci(n):\n    if n <= 1:\n        return n\n    else:\n");
	}
}
